package cn.com.dhcc.ddi.task.dao;

import org.springframework.stereotype.Repository;

import cn.com.dhcc.app.core.dao.BaseDao;
import cn.com.dhcc.app.core.exception.DaoException;
import cn.com.dhcc.app.pub.CM;
import cn.com.dhcc.ddi.task.vo.Task;
import cn.com.dhcc.ddi.task.vo.TaskLog;

/**
 * 
 * @日期：2016/11/28 12:05:01
 * @作者：李博宇
 * @版权所有：东华软件
 * @版本：1.0
 */
@Repository
public class TaskLogDao extends BaseDao{
	 /**
     * 获取对象
     * @param id
     * @return
     * @throws DaoException
     */
    public TaskLog get(String id) throws DaoException {
        return getDao().getModuleById("获取对象",TaskLog.class,new Object[]{id});
    }

    /**
     * 新增
     * @param obj
     * @return
     * @throws DaoException
     */
    public int insert(TaskLog obj) throws DaoException {
        return getDao().insertModule("新增",obj);
    }

    /**
     * 修改
     * @param obj
     * @return
     * @throws DaoException
     */
    public int update(TaskLog obj) throws DaoException {
        return getDao().updateModuleByIdExecuteNull("修改",obj);
    }

    /**
     * 获取任务日志数
     * @param  id 任务日志id
     * @return 任务日志数
     * @throws DaoException
     */
    public int getCount(String id) throws DaoException{
		String msg = "";
		String sql = "select count(*) from "+SI_TABLE("t_ddi_task_log")+"  where task_id = ? and group_id IS NULL";
		try {
			Long taskID=getDao().queryForLong("", sql, new Object[]{id});
			return taskID.intValue();
		} catch (DaoException e) {
			msg = "获取表数据失败";
			throw new DaoException(msg, e);
		}
	}
}
